/**
 * Created by 梁伟鸿 on 2017/12/09.
 */
const mysqlCon = require('./mysqlCon')
//数据插入
var addSql = function(con, sql, paramters, callback){
    //连接数据库
    mysqlCon.connect(con);
    var query = function (callback) {
        con.query(sql, paramters, function (err,result) {
            if(err)
                throw err
            console.log('--------------------------------------------------------------')
            console.log("数据库插入数据\n")
            callback(result);
        })
    }
    //执行数据库语句
    query(callback);
    //关闭数据库
    mysqlCon.close(con)
}
//数据查询
var selectSql = function(con, sql, callback){
    //连接数据库
    mysqlCon.connect(con);
    var query = function (callback) {
        con.query(sql,function (err,result) {
            if(err)
                throw err
            console.log('--------------------------------------------------------------')
            console.log("数据库查询数据\n")
            callback(result);
        })
    }
    //执行数据库语句
    query(callback);
    //关闭数据库
    mysqlCon.close(con)
}
//数据修改
var updateSql = function(con, sql, paramters,  callback){
    //连接数据库
    mysqlCon.connect(con);
    var query = function (callback) {
        con.query(sql, paramters, function (err,result) {
            if(err)
                throw err
            console.log('--------------------------------------------------------------')
            console.log("数据库更新数据\n")
            callback(result);
        })
    }
    //执行数据库语句
    query(callback);
    //关闭数据库
    mysqlCon.close(con)
}
//数据删除
var deleteSql = function(con, sql, callback){
    //连接数据库
    mysqlCon.connect(con);
    var query = function (callback) {
        con.query(sql,function (err,result) {
            if(err)
                throw err
            console.log('--------------------------------------------------------------')
            console.log("数据库删除数据\n")
            callback(result);
        })
    }
    //执行数据库语句
    query(callback);
    //关闭数据库
    mysqlCon.close(con)
}


exports.addSql = addSql
exports.selectSql = selectSql
exports.updateSql = updateSql
exports.deleteSql = deleteSql